from celery_task1.celery import app


@app.task
def aaa(msg):

    return msg